package com.jacky.iot.mediators;

import com.jacky.iot.mqtt.ConnectionManager;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

//@Component
public class ClientReconnectMediator implements Mediator {

    private static final Logger log = LoggerFactory.getLogger(ClientReconnectMediator.class);
    private final ConnectionManager connectionManager;

    public ClientReconnectMediator(final ConnectionManager cm) {
        this.connectionManager = cm;
    }

    @Override
    public void trigger() {
//        try {
//            log.info("trigger mqtt client reconnect...");
////            connectionManager.reconnect();
//        } catch (MqttException e) {
//            log.error("mqtt client reconnect error:", e);
//        }
    }
}
